package asynqmq

import (
	"video-api/utility/queue/asynqmq/logic"
	"video-api/utility/queue/job_type"

	"github.com/hibiken/asynq"
)

func Register() *asynq.ServeMux {

	mux := asynq.NewServeMux()

	//添加历史记录
	mux.Handle(job_type.ScheduleAddDramaHistory, logic.NewAddDramaHistoryHandler())

	//删除历史记录
	mux.Handle(job_type.ScheduleDelDramaHistory, logic.NewDelDramaHistoryHandler())

	return mux
}
